package com.sheepone.distributor.test;

import com.sheepone.distributor.listener.StationEventListener;
import lombok.extern.slf4j.Slf4j;

/**
 * @author Miss.杨
 * @description
 * @since 2023-12-13 17:32
 */
@Slf4j
public class AddStringListener implements StationEventListener<StringContext> {
    @Override
    public void onEvent(StringContext context) {
        context.setValue(context.getValue() + context.getValue());
        DistributorHolder.getDistributor().distribute(StationConstants.READ, TopicConstants.READ, context);
    }

}
